package com.adam.kafkamq.consumer;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author Adam
 * @date 2022/12/9 16:45
 * @desc 订单管理信道接口
 */
public interface OmsSink {


    String TEST_CHANNEL = "test-channel";

    @Input(OmsSink.TEST_CHANNEL)
    SubscribableChannel inputChannel();


    String TEST_DLT_CHANNEL = "topic-name-dlt-channel";

    @Input(OmsSink.TEST_DLT_CHANNEL)
    SubscribableChannel testDltChannel();
}
